package com.ruyuan.rapid.disruptor;


import com.lmax.disruptor.EventHandler;

public class OrderEventHandler implements EventHandler<OrderEvent> {


    @Override
    public void onEvent(OrderEvent event, long sequence, boolean endOfBatch) throws Exception {
        Thread.sleep(100);
        System.out.println("消费一个订单 ,price is " + event.getPrice());
    }
}
